package com.gmall.data.functions;

import com.alibaba.fastjson.JSON;
import com.gmall.data.pojo.LogBean;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author wufengchi
 * @create 2021-04-20 下午11:23
 */
public class Map2BeanMapFunction implements MapFunction<String, LogBean> {
    @Override
    public LogBean map(String s) throws Exception {
        return JSON.parseObject(s, LogBean.class);
    }
}
